from django.core.management.base import BaseCommand
from mqtest.views import start_mq_listener  # 导入你刚写的函数


class Command(BaseCommand):
    help = '启动 MQ 消息监听器'

    def handle(self, *args, **kwargs):
        start_mq_listener()
